
public class MyDefaultMQ {
    public void registerMessageListener(MyMessageListener messageListener) {
        String dd = messageListener.consumeMessage("赵旺");
        if(!dd.equals("自己")){
            System.out.println("我还可以在这里做事情");
        }
    }
}
